package com.kokomi.fanout_model;


import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;


/**
 * 生产者
 * 测试一个生产者发送消息到交换机，交换机发送到多个队列，多个队列发送到多个消费者
 */
@RestController
public class FanoutProducer {


    @Autowired
    private RabbitTemplate rabbitTemplate;


    @GetMapping("/fanoutModel")
    public ResponseEntity<?> fanoutModel() {
        String msg = "广播模型- 一生产 对应 多队列 对应 多消费";
        rabbitTemplate.convertAndSend("fanout_exchange", null, msg);
        return ResponseEntity.ok("广播模型发送成功");
    }



}
